package org.dh2580.delay.queue.bean;

import org.dh2580.delay.queue.bean.model.Ack;

/**
 * @Author: hao.deng
 * @Date: 2019/5/14-下午7:12
 */
public abstract class AbstractMsgListener {

    /**
     * 路由key
     */
    private String routeKey;

    public AbstractMsgListener(String routeKey) {
        this.routeKey = routeKey;
    }

    public String getRouteKey() {
        return routeKey;
    }

    public abstract Ack receiveMsg(String msg);
}
